package com.chinaums.cfps.apps.listener;

import java.util.ArrayList;
import java.util.List;

/**
 * 监听器获取消息
 * 
 * @author cyshao
 * 
 */
public class MessageListener extends AbstractCfpsMQMessageListener {
	private List<String> list = new ArrayList<String>();
	private int startTime=0;
	
	
	/**
	 * 业务代码
	 */
	@Override
	public void execute(String data) {
		if(list.size()==0){
			/*Date date = new Date();
			yyyymmddhhmmss
			startTime=当前时间*/
		}
		list.add(data);
		//将data数据先放入到一个list集合中，定义list最大值为200个，调用多线程的方式进行并发处理
		if(list.size()==200){
			//多线程处理逻辑
		}else{
			//当list为空的时候，开始进行一个时间的标记，定义十秒的时间，在十秒内容，如果list的大小达不到200，依旧开始多线程处理
			/*Date date = new Date();
			yyyymmddhhmmss
			if((当前时间-startTime)>=10){
				//多线程处理逻辑
			}*/
		}
		
		System.out.println("read:" + data);
	}
	
	private void sendMsg(List<String> list){
		
	}

	@Override
	public void stopEvent() {
		// TODO Auto-generated method stub

	}

	@Override
	public boolean isOk() {
		return this.isOk;
	}

}
